package com.ydl.learning.flink.demo.pipeline.java;

import com.ydl.learning.flink.demo.pipeline.java.entity.JobConfig;
import com.ydl.learning.flink.demo.pipeline.java.impl.ConditinoFilterProcessImpl;
import com.ydl.learning.flink.demo.pipeline.java.impl.ConsoleSinkImpl;
import com.ydl.learning.flink.demo.pipeline.java.impl.Pipeline;
import com.ydl.learning.flink.demo.pipeline.java.impl.Pipeline.Builder;
import com.ydl.learning.flink.demo.pipeline.java.impl.TubeStreamSourceInitImpl;

/**
 * @author ydl
 * @since 2022/1/6
 */
public class Main {
  public static void main(String[] args) {

    Pipeline<String> pipeline = new Builder<String>()
        .jobConfig(new JobConfig())
        .init(new TubeStreamSourceInitImpl())
        .process(new ConditinoFilterProcessImpl<>())
        .sink(new ConsoleSinkImpl<>())
        .build();
    pipeline.execute();
  }
}
